package ZguardSuspension;

import lombok.extern.slf4j.Slf4j;

/**
 * @author： pang-yun
 * @date： 2021-11-01 13:18
 * 功能目的 ：用于
 */

@Slf4j
public class Test1 {
    public static void main(String[] args) {
        GuardedObject guardedObject = new GuardedObject();

        // 线程 1  等待结果  线程2 生产  结果
        new Thread(() -> {
            log.info("等待结果！");
            Object o = guardedObject.get(3000);
            System.out.println(o);
        }, "获取结果").start();

        new Thread(() -> {
            log.info("产生结果！");
            String s = "this is response!";

            guardedObject.complete(s);
        }, "产生结果").start();
    }
}


class GuardedObject {
    //结果
    private Object response;
    // 获取结果
    // 超时等待  如果超过时间将 不再等待！
    public Object get(long timeout) {
        synchronized (this) {
            // 开始时间
            long begin = System.currentTimeMillis();
            // 已经等待的时间！
            long passTime = 0;
            while (response == null) {
                if (passTime >= timeout) {
                    break;
                }
                try {
                    this.wait(timeout - passTime);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                // 经历时间
                passTime = System.currentTimeMillis() - begin;
            }
            return response;
        }
    }

    // 产生结果
    public void complete(Object response) {
        synchronized (this) {
            // 给成员  变量赋值
            this.response = response;
            this.notifyAll();
        }
    }
}
